package com.academic.common.scala

import org.apache.spark.sql.SparkSession

object ageprocess {
  private[scala] val spark = SparkSession
    .builder
    .appName("HeartDiseaseAnalysis")
    .master("hdfs://47.120.9.131:8020")
    .appName("Read from HDFS")
    .getOrCreate

  def main(args: Array[String]): Unit = {
    val df = spark.read.parquet("hdfs://47.120.9.131:8020//upload/hadoop/age.parquet")
    df.show
  }
}
